package cn.shadow.concurrent;

import com.lmax.disruptor.EventHandler;
import com.lmax.disruptor.WorkHandler;

/**
 * 事件处理器
 */
public class MyEventHandler implements EventHandler<Event>, WorkHandler<Event>{

    public MyEventHandler() {
    }

    @Override
    public void onEvent(Event event) {
        event.handle();
    }

    @Override
    public void onEvent(Event event, long sequence, boolean endOfBatch) {
        event.handle();
    }
}